from flask import Flask
from flask import request
from concurrent.futures._base import TimeoutError
from concurrent.futures import ThreadPoolExecutor
from kafka import KafkaProducer
import queue
import threading
import time
import json
import random
import datetime
import traceback
import configparser
import sys

app = Flask(__name__)


@app.route('/')
def hello_world():
    return 'Hello World!'


if __name__ == '__main__':
    app.run()
